<html>
    <head>
        <title>使用多个数据库</title>
    </head>
    <body>
        <script>
            /*
                        三、使用多个数据库

                               默认的启动模板被设计成所有模块和你的应用程序都使用用一个数据库。
                               
                               但是，ABP和所有预构建的模块都被设计为可以使用多个数据库。

                               每个模块可以使用自己的数据库，或者你可以将模块分组到几个数据库中。

                               本节将解释如何将审核日志记录、设置管理和权限管理模块表移动到第二个数据库，而其余模块继续使用主（“默认”）数据库。


                                        1、更改连接字符串
                                         
                                                第一步是更改所有appsettings.json文件中的连接字符串部分。最初，它是这样的：

                                                    "ConnectionStrings": {
                                                        "Default": "Server=(LocalDb)\\MSSQLLocalDB;Database=BookStore;Trusted_Connection=True"
                                                    }

                                                更改如下所示：

                                                    "ConnectionStrings": {
                                                        "Default": "Server=(LocalDb)\\MSSQLLocalDB;Database=BookStore;Trusted_Connection=True",
                                                        "AbpPermissionManagement": "Server=(LocalDb)\\MSSQLLocalDB;Database=BookStore_SecondDb;Trusted_Connection=True",
                                                        "AbpSettingManagement": "Server=(LocalDb)\\MSSQLLocalDB;Database=BookStore_SecondDb;Trusted_Connection=True",
                                                        "AbpAuditLogging": "Server=(LocalDb)\\MSSQLLocalDB;Database=BookStore_SecondDb;Trusted_Connection=True"
                                                    }

                                                为相关模块多添加了三个连接字符串，以针对BookStore_SecondDb数据库（它们都是相同的）。

                                                例如，AbpPermissionManagement是权限管理模块使用的连接字符串名称。

                                                "AbpPermissionManagement" 是权限管理模块定义的常量.  
                                                
                                                如果你在appsettings.json文件中这样定义，ABP连接字符串选择系统会为权限管理模块选择此连接字符串。

                                                如果你不定义，它会回退到Default连接字符串。



                                        2、创建第二个DbContext

                                                在运行时定义上面解释的连接字符串就足够了.  但是，BookStore_SecondDb数据库还不存在。你需要为相关模块创建数据库和表。

                                                就像主数据库一样，我们希望使用EF Core Code First迁移系统来创建和维护第二个数据库。

                                                因此，在.EntityFrameworkCore项目创建DbContext类：

                                                        using Microsoft.EntityFrameworkCore;
                                                        using Volo.Abp.AuditLogging.EntityFrameworkCore;
                                                        using Volo.Abp.Data;
                                                        using Volo.Abp.EntityFrameworkCore;
                                                        using Volo.Abp.PermissionManagement.EntityFrameworkCore;
                                                        using Volo.Abp.SettingManagement.EntityFrameworkCore;

                                                        namespace BookStore.EntityFrameworkCore
                                                        {
                                                            [ConnectionStringName("AbpPermissionManagement")]  // 设置连接字符串
                                                            public class BookStoreSecondDbContext :
                                                                AbpDbContext<BookStoreSecondDbContext>
                                                            {
                                                                public BookStoreSecondDbContext(
                                                                    DbContextOptions<BookStoreSecondDbContext> options)
                                                                    : base(options)
                                                                {
                                                                }

                                                                protected override void OnModelCreating(ModelBuilder builder)
                                                                {
                                                                    base.OnModelCreating(builder);

                                                                    // 将依赖模块的DbContext配置到当前DbContext中
                                                                    builder.ConfigurePermissionManagement();
                                                                    builder.ConfigureSettingManagement();
                                                                    builder.ConfigureAuditLogging();
                                                                }
                                                            }
                                                        }

                                                注解： [ConnectionStringName(...)]属性在这里很重要，它告诉ABP应该为此DbContext使用哪个连接字符串。
                                                        
                                                       我们已经使用了AbpPermissionManagement，但都是一样的。

                                                我们需要将这个BookStoreSecondDbContext类注册到依赖注入系统中。

                                                在BookStore.EntityFrameworkCore项目中打开BookStoreEntityFrameworkCoreModule类，并将以下行添加到ConfigureServices方法中：

                                                        context.Services.AddAbpDbContext<BookStoreSecondDbContext>();


                                                我们还应该创建一个Design Time Db Factory类，由EF Core工具使用（例如，通过Add-Migration和Update-DatabasePCM命令）：

                                                        using System.IO;
                                                        using Microsoft.EntityFrameworkCore;
                                                        using Microsoft.EntityFrameworkCore.Design;
                                                        using Microsoft.Extensions.Configuration;

                                                        namespace BookStore.EntityFrameworkCore
                                                        {
                                                            // This class is needed for EF Core console commands
                                                            // (like Add-Migration and Update-Database commands) 
                                                            public class BookStoreSecondDbContextFactory
                                                                : IDesignTimeDbContextFactory<BookStoreSecondDbContext>
                                                            {
                                                                public BookStoreSecondDbContext CreateDbContext(string[] args)
                                                                {
                                                                    var configuration = BuildConfiguration();
                                                                    var builder = new DbContextOptionsBuilder<BookStoreSecondDbContext>()
                                                                        .UseSqlServer(configuration.GetConnectionString("AbpPermissionManagement"));
                                                                    return new BookStoreSecondDbContext(builder.Options);
                                                                }

                                                                private static IConfigurationRoot BuildConfiguration()
                                                                {
                                                                    var builder = new ConfigurationBuilder()
                                                                        .SetBasePath(Path.Combine(Directory.GetCurrentDirectory(), "../BookStore.DbMigrator/"))
                                                                        .AddJsonFile("appsettings.json", optional: false);

                                                                    return builder.Build();
                                                                }
                                                            }
                                                        }

                                                现在，你可以打开包管理器控制台，选择.EntityFrameworkCore项目作为默认项目（确保.Web项目仍然是启动项目）并运行以下命令：

                                                        " Add-Migration "Initial" -OutputDir "SecondDbMigrations" -Context BookStoreSecondDbContext "

                                                这将在.EntityFrameworkCore项目中添加一个 "SecondDbMigrations文件夹" 和其中的迁移类。

                                                OutputDir和Context参数是必需的，因为我们目前在同一个项目中有两个DbContext类和两个迁移文件夹。

                                                你现在可以运行以下命令来创建数据库及其中的表：

                                                        "Update-Database -Context BookStoreSecondDbContext"

                                                应该创建一个名为 " BookStore_SecondDb " 的新数据库。


                                    3、从主数据库中删除模块

                                            我们已经创建了第二个数据库，其中包含审计日志记录、权限管理和设置管理模块的表。

                                            因此，我们应该从主数据库中删除这些表。这很容易。

                                            首先，从BookStoreDbContext类中删除以下行：

                                                    builder.ConfigurePermissionManagement();
                                                    builder.ConfigureSettingManagement();
                                                    builder.ConfigureAuditLogging();   
                                                    
                                            打开包管理器控制台，选择.EntityFrameworkCore作为默认项目（确保.Web项目仍然是启动项目）并运行以下命令：

                                                    " Add-Migration "Removed_Audit_Setting_Permission_Modules" -Context BookStoreDbContext " 
                                                        
                                            此命令将创建一个新的迁移类，如下所示：

                                                    public partial class Removed_Audit_Setting_Permission_Modules : Migration
                                                    {
                                                        protected override void Up(MigrationBuilder migrationBuilder)
                                                        {
                                                            migrationBuilder.DropTable(
                                                                name: "AbpAuditLogActions");

                                                            migrationBuilder.DropTable(
                                                                name: "AbpEntityPropertyChanges");

                                                            migrationBuilder.DropTable(
                                                                name: "AbpPermissionGrants");

                                                            migrationBuilder.DropTable(
                                                                name: "AbpSettings");

                                                            migrationBuilder.DropTable(
                                                                name: "AbpEntityChanges");

                                                            migrationBuilder.DropTable(
                                                                name: "AbpAuditLogs");
                                                        }

                                                        ...
                                                    }

                                             在这一步中要小心：

                                                    如果你有一个live system，那么你应该关心数据丢失。在删除表之前，你需要将表内容移动到第二个数据库。
                                                    
                                                    如果你尚未启动你的项目，你可以考虑删除所有迁移并重新创建初始迁移以获得更清晰的迁移历史记录。

                                            运行以下命令从主数据库中删除表：

                                                    "Update-Database -Context BookStoreDbContext"


                                            ★、注意： 请注意，如果你没有将初始种子数据复制到新数据库，你还删除了一些初始种子数据（例如，管理员角色的权限授予）。
                                                      如果你运行应用程序，你可能不再登录。
                                                      解决方案很简单：重新运行.DbMigrator控制台应用程序在你的解决方案中，它将为新数据库播种。

                                    

                                    4、让第二数据库的迁移实现自动化  

                                                .DbMigrator控制台应用程序可以跨多个数据库运行数据库种子代码,，无需任何额外配置。

                                                但是，它不能为BookStoreSecondDbContext的数据库应用EF Core Code First Migrations。

                                                现在，你将看到如何配置控制台迁移应用程序来处理这两个数据库。

                                                EntityFrameworkCoreBookStoreDbSchemaMigrator是在Acme.BookStore.EntityFrameworkCore项目中的类，
                                                
                                                负责迁移BookStoreMigrationsDbContext的数据库模式。应该是这样的：

                                                            using System;
                                                            using System.Threading.Tasks;
                                                            using Microsoft.EntityFrameworkCore;
                                                            using Microsoft.Extensions.DependencyInjection;
                                                            using BookStore.Data;
                                                            using Volo.Abp.DependencyInjection;

                                                            namespace BookStore.EntityFrameworkCore
                                                            {
                                                                public class EntityFrameworkCoreBookStoreDbSchemaMigrator
                                                                    : IBookStoreDbSchemaMigrator, ITransientDependency
                                                                {
                                                                    private readonly IServiceProvider _serviceProvider;

                                                                    public EntityFrameworkCoreBookStoreDbSchemaMigrator(
                                                                        IServiceProvider serviceProvider)
                                                                    {
                                                                        _serviceProvider = serviceProvider;
                                                                    }

                                                                    public async Task MigrateAsync()
                                                                    {
                                                                        // We intentionally resolving the BookStoreDbContext
                                                                        // from IServiceProvider (instead of directly injecting it)
                                                                        // to properly get the connection string of the current tenant in the
                                                                        // current scope.

                                                                        await _serviceProvider
                                                                            .GetRequiredService<BookStoreDbContext>()
                                                                            .Database
                                                                            .MigrateAsync();
                                                                    }
                                                                }
                                                            }

                                                在MigrateAsync方法中添加以下代码：

                                                            await _serviceProvider
                                                                                .GetRequiredService<BookStoreSecondDbContext>()
                                                                                .Database
                                                                                .MigrateAsync();

                                                因此，MigrateAsync方法应如下所示：
                                                                            
                                                            public async Task MigrateAsync()
                                                            {
                                                                // We intentionally resolving the BookStoreDbContext
                                                                    * from IServiceProvider (instead of directly injecting it)
                                                                    * to properly get the connection string of the current tenant in the
                                                                    * current scope.

                                                                await _serviceProvider
                                                                    .GetRequiredService<BookStoreDbContext>()
                                                                    .Database
                                                                    .MigrateAsync();

                                                                await _serviceProvider
                                                                    .GetRequiredService<BookStoreSecondDbContext>()
                                                                    .Database
                                                                    .MigrateAsync();
                                                            }

                                                就是这么简单。你现在可以运行.DbMigrator应用程序来迁移和播种数据库。

                                                要进行测试话，可以删除两个数据库并再次运行.DbMigrator应用程序以查看它是否创建了两个数据库。




                                   5、修复测试  Fixing the Tests 
                                   
                                            创建新的DbContext会破坏集成测试。很容易修复。

                                            在BookStore.EntityFrameworkCore.Tests项目中打开BookStoreEntityFrameworkCoreTestModule类，找到CreateDatabaseAndGetConnection方法。
                                            
                                            应该是这样的：
                                                                        
                                                    private static SqliteConnection CreateDatabaseAndGetConnection()
                                                    {
                                                        var connection = new SqliteConnection("Data Source=:memory:");
                                                        connection.Open();

                                                        var options = new DbContextOptionsBuilder<BookStoreDbContext>()
                                                            .UseSqlite(connection)
                                                            .Options;

                                                        using (var context = new BookStoreDbContext(options))
                                                        {
                                                            context.GetService<IRelationalDatabaseCreator>().CreateTables();
                                                        }

                                                        return connection;
                                                    }
                                            
                                            将其更改为以下内容：

                                                    private static SqliteConnection CreateDatabaseAndGetConnection()
                                                    {
                                                        var connection = new SqliteConnection("Data Source=:memory:");
                                                        connection.Open();

                                                        var options = new DbContextOptionsBuilder<BookStoreDbContext>()
                                                            .UseSqlite(connection)
                                                            .Options;

                                                        using (var context = new BookStoreDbContext(options))
                                                        {
                                                            context.GetService<IRelationalDatabaseCreator>().CreateTables();
                                                        }

                                                        // Add the following code --------------
                                                        var optionsForSecondDb = new DbContextOptionsBuilder<BookStoreSecondDbContext>()
                                                            .UseSqlite(connection)
                                                            .Options;

                                                        using (var context = new BookStoreSecondDbContext(optionsForSecondDb))
                                                        {
                                                            context.GetService<IRelationalDatabaseCreator>().CreateTables();
                                                        }
                                                        //--------------------------------------

                                                        return connection;
                                                    }    
                                                        
                                        集成测试现在可以工作了。我在测试中使用了相同的数据库以保持简单。
                    */
        </script>
    </body>
</html>